package net.wicp.tams.common.binlog.self.constant;

/***
 * send需要的参数变量
 * 
 * @author zhoujunhui
 *
 */
public abstract class ParamsVar {
	public final static String TOPIC = "topic";// kafka和ons需要
	public final static String PID = "pid";// ons需要
	public final static String SERIALIZE = "serialize";// serialize

	// 公共参数
	public final static String MULTITHREAD = "_multiThread";// 是否多线程
	public final static String THREADNUM = "_threadNum";// 多线程数量
	public final static String QUERYSIZE = "_querySize";// 队列大小
	public final static String SPLITKEY = "_splitKey";// 分库分表键
	public final static String TABLENUM = "_tableNum";// 此实例的表数量
	public final static String SENDBYTABLE = "_sendByTable";// 是通过表名做为hash发送
}
